
package com.xuecheng.media.service.impl;

import cn.hutool.core.bean.BeanUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;

import com.j256.simplemagic.ContentInfo;
import com.j256.simplemagic.ContentInfoUtil;
import com.xuecheng.model.PageParams;
import com.xuecheng.base.execption.XueChengPlusException;
import com.xuecheng.model.PageResult;
import com.xuecheng.media.mapper.MediaFilesMapper;
import com.xuecheng.media.model.dto.QueryMediaParamsDto;
import com.xuecheng.media.model.dto.UploadFileParamsDto;
import com.xuecheng.media.model.dto.UploadFileResultDto;
import com.xuecheng.media.model.po.MediaFiles;
import com.xuecheng.media.service.MediaFileService;
import io.minio.MinioClient;
import io.minio.UploadObjectArgs;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.File;
import java.io.FileInputStream;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.util.Date;
import java.util.List;

/**
 * @description TODO
 * @author Mr.M
 * @date 2022/9/10 8:58
 * @version 1.0
 */
 @Service
 @RequiredArgsConstructor
 @Slf4j
public class MediaFileServiceImpl implements MediaFileService {

  private final MediaFilesMapper mediaFilesMapper;

  @Autowired
  private MediaFileService mediaFileService;
  private final MinioClient minioClient;

  @Value("${minio.bucket.files}")
  private String bucket_files;

  @Override
  public PageResult<MediaFiles> queryMediaFiels(Long companyId, PageParams pageParams, QueryMediaParamsDto queryMediaParamsDto) {
   //构建查询条件对象
   LambdaQueryWrapper<MediaFiles> queryWrapper = new LambdaQueryWrapper<>();
      queryWrapper.like(MediaFiles::getFilename,queryMediaParamsDto.getFilename());
  //分页对象
  Page<MediaFiles> page = new Page<>(pageParams.getPageNo(), pageParams.getPageSize());

  // 查询数据内容获得结果
  Page<MediaFiles> pageResult = mediaFilesMapper.selectPage(page, queryWrapper);
  // 获取数据列表
  List<MediaFiles> list = pageResult.getRecords();
      log.info("{}",list);
  // 获取数据总数
  long total = pageResult.getTotal();
  // 构建结果集
  PageResult<MediaFiles> mediaListResult = new PageResult<>(list, total, pageParams.getPageNo(), pageParams.getPageSize());

  return mediaListResult;

 }


    //不开启事务是因为传文件过程时间较长那么数据库的事务持续时间就会变长，这样数据库链接释放就慢，最终导致数据库链接不够用。
    @Override
    public UploadFileResultDto uploadFile(Long companyId, String path, UploadFileParamsDto uploadFileResultDto,String objectName) {
        File file = new File(path);
        if(!file.exists()){
            XueChengPlusException.cast("文件不存在");
        }
        //文件名称
        String fileName=uploadFileResultDto.getFilename();
        //将文件上传至分布式文件系统
        //文件拓展名
        String exension = fileName.substring(fileName.lastIndexOf("."));
        //文件的md5值
        String fileMd5 = getFileMd5(file);
        //文件的默认目录
        String defaultFolderPath = getTime();
        //存储到minio中的对象名(带目录)

        //如果为空，采用日期路径
        if(StringUtils.isEmpty(objectName)){
            objectName = defaultFolderPath + fileMd5 + exension;
        }
        upload(path,uploadFileResultDto.getFileType(),objectName);
        //在媒资管理数据库保存文件信息
        MediaFiles mediaFiles=mediaFileService.addMediaFilesToDb(companyId,uploadFileResultDto,fileMd5,objectName);//通过代理对象调用才会开启事务
        //上传图片成功保存图片地址到课程基本信息表中
        UploadFileResultDto uploadFileResultDto1 = BeanUtil.copyProperties(mediaFiles, UploadFileResultDto.class);
        return uploadFileResultDto1;
    }


    //保存文件信息到数据库中
    @Transactional//通过代理对象调用才会开启事务
    public  MediaFiles addMediaFilesToDb(Long companyId, UploadFileParamsDto uploadFileResultDto,String filrMd5,String objectName) {
      //从数据库中查询信息
        MediaFiles media = mediaFilesMapper.selectById(filrMd5);
        if(media!=null)return media;
        //文件名称、类型、大小、标签、上传人、备注
        MediaFiles mediaFiles = BeanUtil.copyProperties(uploadFileResultDto, MediaFiles.class);
        //公司标识
        mediaFiles.setCompanyId(companyId);
        //上传的bucket
        mediaFiles.setBucket(bucket_files);
        //主键id
        mediaFiles.setId(filrMd5);
        //文件路径
        mediaFiles.setFilePath(objectName);
        //文件id
        mediaFiles.setFileId(filrMd5);
        //文件的访问路径
        mediaFiles.setUrl("/" + bucket_files + "/" + objectName);
        //创建更新时间
        mediaFiles.setCreateDate(LocalDateTime.now());
        mediaFiles.setChangeDate(LocalDateTime.now());
        //状态
        mediaFiles.setStatus("1");
        //审核状态
        mediaFiles.setAuditStatus("002003");
        int i = mediaFilesMapper.insert(mediaFiles);
        if(i<=0){
            log.error("保存文件信息到数据库失败,{}",mediaFiles.toString());
            XueChengPlusException.cast("保存文件信息失败");
        }
        return mediaFiles;
    }

    @Override
    public MediaFiles getFileById(String mediaId) {
        return mediaFilesMapper.selectById(mediaId);
    }

    //获取文件的md5加密
    private String getFileMd5(File file) {
        try (FileInputStream fileInputStream = new FileInputStream(file)) {
            String fileMd5 = DigestUtils.md5Hex(fileInputStream);
            return fileMd5;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }


    //上传文件到minlo
    public void upload(String path,String typed,String objectName){
        //根据扩展名取出mimeType
        ContentInfo extensionMatch = ContentInfoUtil.findExtensionMatch(typed);
        //二进制流数据（如常见的文件下载）
        String mimeType = MediaType.APPLICATION_OCTET_STREAM_VALUE;
        if(extensionMatch!=null){
            mimeType = extensionMatch.getMimeType();
        }
        try {
            UploadObjectArgs testbucket = UploadObjectArgs.builder()
                    .bucket(bucket_files)
//                    .object("test001.mp4")
                    //获取文件时间
                    .object(objectName)//添加子目录
                    .filename(path)
                    .contentType(mimeType)//默认根据扩展名确定文件内容类型，也可以指定
                    .build();
            minioClient.uploadObject(testbucket);
            log.debug("上传文件到minio成功,bucket:{},objectName:{}",bucket_files,objectName);
        } catch (Exception e) {
            e.printStackTrace();
            log.error("上传文件到minio出错,bucket:{},objectName:{},错误原因:{}",bucket_files,objectName,e.getMessage(),e);
            XueChengPlusException.cast("上传文件到文件系统失败");
        }

    }

    //获取时间
    private String getTime() {
        SimpleDateFormat date = new SimpleDateFormat("yyyy-MM-dd");
        String replace = date.format(new Date()).replace('-', '/')+"/";
        return replace;
    }
}
